package com.corpgovernment.common.utils;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @ClassName: OrderMonitorExecutorUtil
 * @description: TODO
 * @author: jiang.luo
 * @date: Created in 14:42 2019/8/29
 * @Version: 1.0
 **/
public class OrderMonitorExecutorUtil {
    private static BlockingQueue<Runnable> blkQueue = new ArrayBlockingQueue<Runnable>(100);
    public static ThreadPoolExecutor orderExecutor = new ThreadPoolExecutor(2 * Runtime.getRuntime().availableProcessors(),
            50, 50, TimeUnit.MILLISECONDS, blkQueue,new NameThreadFactory("订单监控"));

}
